
#include "Logging.h"
#include "Mutex.h"
#include "TcpClient.h"
#include "EventLoop.h"
#include "TcpConnection.h"
#include "CountDownLatch.h"
#include "EventLoopThread.h"
#include "../third/muduo/proto/dispatcher.h"
#include "../mqClient/worker.hpp"

using namespace std;
using namespace muduo::net;

int main()
{
    AsyncWorker::ptr worker = make_shared<AsyncWorker>();
    TcpClient client(worker->loopthread.startLoop(), muduo::net::InetAddress("127.0.0.1", 8081), "client");
    client.connect();
    DLOG("连接成功");

}
